package com.aiwiown.snackmq.common.dto.console;

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;

/**
 * 用于封装单个分区延迟信息的数据传输对象。
 */
@Data
@NoArgsConstructor
@AllArgsConstructor
public class PartitionLagDTO {
    /**
     * 主题与分区的组合键，格式为 "topic:partitionId"
     */
    private String topicPartition;
    /**
     * 已提交的位点
     */
    private long committedOffset;
    /**
     * 分区的最高水位线（最新消息位点）
     */
    private long highWatermark;
    /**
     * 当前分区的消息积压量 (lag)
     */
    private long lag;
}